﻿using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Diagnostics;
using System.Linq;
using System.ServiceProcess;
using System.Text;
using System.Threading.Tasks;
using DynamicDnsChanger.Extensions;
using DynamicDnsChanger.MEF;
using System.Diagnostics.Contracts;
using System.IO;
using System.Reflection;
namespace DynamicDnsChanger
{
    partial class DynamicDnsChangerService : ServiceBase
    {
        System.Threading.Timer _UpdateTimer;
        String CurrentIP = "";
        ICheckIP CheckIpPlugin;
        IList<IUpdater> UpdaterPlugins;
        IRequester RequesterPlugin;
        private bool IsFirstTime;
        public DynamicDnsChangerService()
        {
            InitializeComponent();
            IsFirstTime = true;
            //Definir localização dos plugins
            try
            {
                _UpdateTimer = new System.Threading.Timer((s) =>
                {

                    try
                    {
                        //Console.Clear();
                        Console.WriteLine("Checando IP...");
                        this.CheckIpPlugin.Check();
                    }
                    catch (Exception ex)
                    {
                        Log("_UpdateTimer: " + ex.Message);
                    }

                });

                string PluginPath = String.Concat(new FileInfo(Assembly.GetExecutingAssembly().Location).Directory, @"\Plugins");
                //Carregar os plugins
                if (!Directory.Exists(PluginPath))
                {
                    Log("Diretório Plugins não localizado: " + PluginPath);
                    return;
                }
                GenericPluginLoader<IRequester> loader1 = new GenericPluginLoader<IRequester>(PluginPath);
                Contract.Requires(loader1 != null, "Requester");
                RequesterPlugin = loader1.Plugins.FirstOrDefault(x => x != null);
                RequesterPlugin.StatusChange += (s, evt) => { };
                //
                GenericPluginLoader<ICheckIP> loader2 = new GenericPluginLoader<ICheckIP>(PluginPath, RequesterPlugin);
                Contract.Requires(loader2 != null, "ICheckIP");
                CheckIpPlugin = loader2.Plugins.FirstOrDefault();
                //
                GenericPluginLoader<IUpdater> loader3 = new GenericPluginLoader<IUpdater>(PluginPath, RequesterPlugin);
                Contract.Requires(loader3 != null, "IUpdater");
                UpdaterPlugins = loader3.Plugins.ToList();
                //Definir ações para os eventos dos plugins IUpdater
                UpdaterPlugins.ToList().ForEach(x =>
                {
                    x.StatusChange += (s, evt) =>
                    {
                        if (evt.TypeOfMessage != TypeOfMessage.Success)
                        {
                            //TODO: Criar log
                            Log(String.Concat(evt.TypeOfMessage.ToString(), " - ", evt.Message));
                        }
                        else
                        {
                            Log(evt.Message);
                            
                        }
                    };
                });

                //
                CheckIpPlugin.StatusChange += (s, evt) =>
                {
                    if (evt.TypeOfMessage == TypeOfMessage.Success)
                    {
                        if (evt.Message != CurrentIP)
                        {
                            //Definir o novo IP
                            CurrentIP = evt.Message;
                            //Gravar no log
                            Log(String.Format("Definindo novo IP: {0}", CurrentIP));
                            //Atualizar os DNS
                            foreach (var item in UpdaterPlugins)
                            {
                                item.Update(CurrentIP);
                            }
                        }
                    }
                };

            }
            catch (Exception ex)
            {
                Log(ex.Message);
            }

        }

        private void Log(string Message)
        {
            if (Environment.UserInteractive)
            {
                Console.WriteLine(Message);
            }
            else
            {
                EventLog.WriteEntry(Message);
            }
            
        }

        protected override void OnStart(string[] args)
        {
            // TODO: Adicione aqui o código para iniciar seu serviço.
            if (IsFirstTime)
            {
                //Checar Imediatamente
                this.CheckIpPlugin.Check();
                IsFirstTime = false;
            }
            ChangeTimerInterval((int)TimeSpan.FromMinutes(1).TotalMilliseconds);
        }

        protected override void OnStop()
        {
            // TODO: Adicione aqui o código para realizar qualquer desmontagem necessária para interromper seu serviço.
            ChangeTimerInterval(-1);
        }

        internal void Start()
        {
            OnStart(new string[] { });
        }

        private void ChangeTimerInterval(int Milliseconds)
        {
            if (Milliseconds == -1)
            {
                _UpdateTimer.Change(System.Threading.Timeout.Infinite, System.Threading.Timeout.Infinite);
            }
            else
            {
                _UpdateTimer.Change(Milliseconds, Milliseconds);
            }
        }
    }
}
